package com.ydl.learning.flink.demo.pipeline.impl

import com.ydl.learning.flink.demo.pipeline.{BaseProcedureImpl, Process}
import org.apache.flink.streaming.api.scala.{DataStream, _}

/**
 *
 *
 * @author ydl
 * @since 2022/1/7
 */
class ProcessImpl extends Process[String] with BaseProcedureImpl {


  override def run: DataStream[String] = {
    this.dataStream.flatMap(_.split(" ")).name("split space")
  }
}
